from threading import Thread


class Consumer(Thread):
    def __init__(self):
        super().__init__()
        self.connection = None
        self.channel = None

    def run(self):
        pass

    def close(self):
        if self.connection is not None:
            self.connection.close()
